#!usr/bin/env python
# -*- coding:utf-8 _*-
""" 
@author:robot
@file: tap_connector24_clickhouse.py
@version:
@time: 2022/01/13 
"""
import clickhouse_driver
from TapClientConnector.connector.tap_connector23_hana import *


class TAPClickHouseConnector(TAPMysqlConnector):

    def __init__(self, kwargs):
        super(TAPMysqlConnector, self).__init__(kwargs)
        self.FORMAT_DB_INFO['port'] = self.DB_INFO.get('python_port')
        self.connector = clickhouse_driver.connect(**self.FORMAT_DB_INFO)


